package com.myself.storm_test;

import backtype.storm.Constants;
import backtype.storm.tuple.Tuple;
/**
 * 定时帮助
 */
public final class TupleHelpers {

	private TupleHelpers() {
	}

	public static boolean isTickTuple(Tuple tuple) {
		return tuple.getSourceComponent().equals(Constants.SYSTEM_COMPONENT_ID) && tuple.getSourceStreamId().equals(Constants.SYSTEM_TICK_STREAM_ID);
	}

}
